<script>
	import apis from '@/common/api.js';
	export default {
		globalData: {
			apis: {},
			staticView: {},
		},
		onLaunch: function() {
			// #ifdef APP-PLUS
			plus.screen.lockOrientation('portrait-primary');
			// #endif
			const token = apis.getToken();
			if (!token) {
				uni.redirectTo({
					url: '/pages/login/login'
				});
				return;
			}
			this.connectSocketInit();
			uni.$on("hasLogined", () => {
				this.connectSocketInit();
			})
			console.log("onlaunch")
		},
		onShow: function() {
			this.connectSocketInit();
		},
		onHide: function() {
			console.log('App Hide')
		},
		methods: {
			// 进入这个页面的时候创建websocket连接【整个页面随时使用】
			connectSocketInit() {
				let that = this;
				let token = apis.getToken();
				if (!token) {
					return;
				}
				apis.composeUrl();
				let wsUrl = apis.getWebSocketUrl();
				// 创建一个this.socketTask对象【发送、接收、关闭socket都由这个对象操作】
				this.socketTask = uni.connectSocket({
					// 【非常重要】必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099【特别容易犯的错误】
					url: wsUrl,
					success(data) {
						console.log("websocket连接成功");
					},
				});

				// 消息的发送和接收必须在正常连接打开中,才能发送或接收【否则会失败】
				this.socketTask.onOpen((res) => {
					console.log("WebSocket连接正常打开中...！");
					this.is_open_socket = true;
					console.info("token", token)
					// 注：只有连接正常打开中 ，才能正常成功发送消息
					this.socketTask.send({
						data: token,
						async success() {
							console.log("消息发送成功");
						},
					});
					that.timer = setInterval(() => {
						that.socketTask.send({
							data: '1',
							async success() {
								console.info("心跳发送成功");
							},
							async error() {
								console.info("心跳发送失败");
							}
						})
					}, 30 * 1000)
					// 注：只有连接正常打开中 ，才能正常收到消息
					this.socketTask.onMessage((res) => {
						if (null == res || null == res.data) {
							return;
						};
						//当接收到服务器推送的消息时，处理的方法在这里写
						let message = res.data;
						console.log("收到服务器内容：" + res.data);
						if (res.data == "welcome") {
							return;
						};
						let messageContext = JSON.parse(message);
						uni.$emit("swipeCardResult", messageContext);
						
					});
				});
				// 这里仅是事件监听【如果socket关闭了会执行】
				this.socketTask.onClose(() => {
					uni.showToast({
						title: '连接关闭了',
						icon: 'none',
						duration: 1000
					})
					console.log("已经被关闭了")
				});
			},
			// 关闭websocket【离开这个页面的时候执行关闭】
			closeSocket() {
				let that = this;
				console.info("页面开始关闭websocket");
				this.socketTask.close({
					success(res) {
						that.is_open_socket = false;
						console.log("关闭成功", res)
					},
					fail(err) {
						console.log("关闭失败", err)
					}
				});
			},
			//重新连接websock
			reconnectingWebsock() {
				let _this = this;
				//判断网络是否连接
				uni.onNetworkStatusChange(function(res) {
					if (res.isConnected) {
						uni.showToast({
							title: '网络已恢复',
							icon: 'none',
							duration: 2000
						});
						if (!_this.is_open_socket) {
							_this.connectSocketInit();
						}
					} else {
						uni.showToast({
							title: '网络不可用',
							icon: 'none',
							duration: 2000
						});
					}
				});
			}
		}
	}
</script>

<style>
	/*每个页面公共css */
</style>
